package flink.function;

import org.apache.flink.api.common.functions.MapFunction;

import com.alibaba.fastjson.JSONObject;

/**
 * @author ：Jason
 * @date ：Created in 2023/4/30 1:14 PM
 * @description： 把 Java POJO 类型转成 JSONObject 类型
 * @modified By：
 * @version: 1.0
 */
public class MapEntityToJSONObjectFunction<T, O> implements MapFunction<T, JSONObject> {
    @Override
    public JSONObject map(T value) throws Exception {
        return (JSONObject) JSONObject.toJSON(value);
    }
}
